var express = require('express');
var router = express.Router();
var superagent = require('superagent');
var logger = require('../log4j').logger;
var logger_error = require('../log4j').logger_error;
var redis = require('redis');
var config = require('../config.js');
var client  = redis.createClient(config.redis.port,config.redis.ip);
// var client  = redis.createClient('6379','127.0.0.1');
client.auth(config.redis.pwd);
client.select(config.redis.db);
// client.select('0');

/* GET home page. */
router.get('/cambodia', function(req, res, next) {
  var thisUrl = req.url;
  var shareUrl = encodeURIComponent((global.browserURL +'/cambodia'+thisUrl).split('#')[0]);
  superagent
  .get(global.wechatURL + '/wechat_api/jsconfig?url=' + shareUrl)
  .end(function(err2, res2) {
    if (res2 !== undefined && res2.ok) {
      res2.body.browserUrl = global.browserURL;
      res.render('cambodia/index',res2.body);
    } else {
      console.error('微信分享api错误。');
      logger_error.error('cambodia.js.......微信分享api错误。'+JSON.stringify(err2));
    }
  });
});

router.get('/place',function  (req,res,next) {
  logger.info('cambodia.js.......place:'+JSON.stringify(req.query));
	var id = req.query.id;
	var thisUrl = req.url;
	var shareUrl = encodeURIComponent((global.browserURL +'/cambodia'+thisUrl).split('#')[0]);
    superagent
    .get(global.wechatURL + '/wechat_api/jsconfig?url=' + shareUrl)
    .end(function(err2, res2) {
	    if (res2 !== undefined && res2.ok) {
	        res2.body.browserUrl = global.browserURL;
	        res2.body.id = id;
	        client.lrange('cambodiaUser',0,-1,function  (err,message) {
				if(err){
					console.log(err);
				}else{
					// console.log(message);
					var strMessage = JSON.stringify(message);
          res2.body.info = strMessage;
					res.render('cambodia/place',res2.body);
				}
			})
	    }else {
        logger_error.error('cambodia.js.......微信分享api错误。'+JSON.stringify(err2));
	      console.error('微信分享api错误。');
	    }
  	});
})

router.get('/goods',function  (req,res,next) {
  logger.info('cambodia.js.......goods:'+JSON.stringify(req.query));
  res.render('cambodia/goods');
})

router.get('/data',function  (req,res,next) {
	client.rpush('cambodiaUser','哇，好漂亮~~~~~','强势路过前来留名。','我也去过柬埔寨，现在看看很怀念呐~~~','认真你就输了!','2333333发个弹幕挺好玩~','我觉得这个做的挺好的，关注一下~','旅行直播？好像很好玩的样子~~~~','乐可旅行？我去搜搜','柬埔寨竟然能玩出这么多花样，厉害了！','关注下柬埔寨的直播刚好过两天要去！','我是来看主播的！我要表白~比心','主播去柬埔寨可以代购吗？','这些地方貌似我都去过的样子~','好友安利，强势围观！','朋友说这里留了给我看的我来围观一下~','我觉得旅行直播这个概念挺好的，持续关注。','之前你们是不是去了巴厘岛呀？','怎么看直播？要下载APP？','Get时间关注一波~','好想知道播点什么，先关注一下~','图片很美，有点想去柬埔寨了。','我想知道一般人能直播吗？','希望直播的时候多讲点关于景点的注意事项。','先下载下乐可旅行APP看看就是干嘛的~','前方高能预警！！','弹幕护体！！','柬埔寨有没有好吃的呀！','来看看有没有美女主播！','突然有点期待这次直播么~~~','能不能免费送我去旅行呀233333~');
})

router.get('/showBarrage',function  (req,res,next) {
	client.lrange('cambodiaUser',30,-1,function  (err,message) {
		if(err){
			console.log(err);
		}else{
			res.render('cambodia/showBarrage',{barrage:message});
		}
	})
})

router.post('/message',function  (req,res,next) {
  logger.info('请求数据库');
	var barrage = req.body.content;
	client.rpush('cambodiaUser',barrage,function (err,message) {
		if (err) {
			console.log(err);
		}else{
    		res.send({data:'成功啦'});
		};
	})
})

module.exports = router;
